package com.gzcstec.product.mq.receiver;

import com.gzcstec.product.dataobject.DecreaseStockInput;
import com.gzcstec.product.mq.client.ProductMqInput;
import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;

@EnableBinding(value = {ProductMqInput.class})
@Slf4j
public class ProductMqReceiver {

//    @StreamListener(value = ProductMqInput.decreaseStock)
    public void receiveDecreaseStockMq(DecreaseStockInput decreaseStockInput) {
        log.info("接收减库存消息：message={}" , decreaseStockInput);
    }

}
